package org.event.core.service.consumer.impl;

import lombok.extern.slf4j.Slf4j;
import org.event.core.entity.InspectorIssue;
import org.event.core.entity.Notice;
import org.event.core.service.consumer.KafkaConsumerService;
import org.springframework.stereotype.Service;

/**
 * 消费实现
 *
 * @author zhangjm
 * @date 2023年11月29日 13:08
 */
@Slf4j
@Service
public class KafkaConsumerServiceImpl implements KafkaConsumerService {


    @Override
    public void inspectorListener(InspectorIssue inspectorIssue) {
        log.error("督查督办监听消息----开始处理................");
        log.error("督查督办监听消息----发处理中................");
        log.error("督查督办监听消息----处理结束................");

    }

    @Override
    public void noticeListener(Notice notice) {
        log.error("通知通报开始--开始处理................");
        log.error("通知通报开始--处理中................");
        log.error("通知通报开始--处理结束................");

    }

}
